package com.zr.domain.bar.service.fun;

import com.zr.domain.bar.entity.KLine;
import com.zr.domain.bar.entity.MarketDataEvent;
import com.zr.domain.bar.reposotory.RedisSinkRepository;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;

public class RedisSink implements SinkFunction<MarketDataEvent> {
    @Override
    public void invoke(MarketDataEvent value, Context context) {
        RedisSinkRepository.storeKLineToRedis(value);
    }
}
